package com.we.flink.userlabelplatform.table;

public class TableUserPhoneInfo {
    public static final String KFKTABLE = "fdm.hhl01_user_phone_info";
    public static final String QUERYSQL =
            "select uid, "
                    + "if(platform is null, '', platform) platform, "
                    + "if(channel is null, '', channel) channel, "
                    + "updated_at "
                    + "from "
                    + KFKTABLE
                    + " where uid <> 0 and deleted_at is null and updated_at is not null and (platform IS NOT NULL or channel IS NOT NULL) "
                    + " and updated_at >= 1681401600 ";

    public long uid;
    public String platform;
    public String channel;
    public int updated_at;

    public TableUserPhoneInfo() {}

    public TableUserPhoneInfo(long uid, String platform, String channel, int updated_at) {
        this.uid = uid;
        this.platform = platform;
        this.channel = channel;
        this.updated_at = updated_at;
    }

    public long getUid() {
        return uid;
    }

    public String getPlatform() {
        return platform;
    }

    public String getChannel() {
        return channel;
    }

    public int getUpdated_at() {
        return updated_at;
    }

    @Override
    public String toString() {
        return "TableUserPhoneInfo{"
                + "uid="
                + uid
                + ", platform='"
                + platform
                + '\''
                + ", channel='"
                + channel
                + '\''
                + ", updated_at="
                + updated_at
                + '}';
    }
}
